package cn.tramy.pinxian.wind.eventstore

import cn.tramy.pinxian.wind.eventstore.domain.model.DomainEvent
import reactor.core.publisher.Flux

interface EventStore {
    fun appendEvent(event: DomainEvent)
    fun readEvents(aggregateId: String, aggregateType: Class<Any>): Flux<DomainEvent>
}